package com.sh.data.engine.domain.datadev.flink.model.domain;

import lombok.Data;

import java.util.List;

@Data
public class FlinkHiveSinkConfigDomain extends FlinkSinkConfigDomain {
    private String tableName;

    /**
     * 更新模式，0-全量 1-增量
     */
    private Integer dataMode;

    /**
     * dataMode为1时，需要选择主键字段
     */
    private List<String> primaryFields;

    // private List<FlinkFieldDomain> partitionFields;
}
